logstash消费Kafka消息，报错：javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,i

当input里面有多个kafka输入源时，client_id => "logstash-1-1"，必须添加且需要不同， 否则会报错javax.management.InstanceAlread ...